package cn.z2huo.demo.hello.kafka.model;

import lombok.Data;

import java.io.Serial;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

/**
 * <p>
 *
 * @author z2huo
 */
@Data
public class KafkaMessage<K extends Serializable, V> implements Serializable {

    @Serial
    private static final long serialVersionUID = -6720880224302026138L;

    private String transactionCode;

    private String originSystem;

    private int gray;

    private List<KafkaRequest<K, V>> messageBody = new ArrayList<>();

    private String topic;
}
